package org.ring.config.server;

import org.ring.common.transport.Connection;

/**

 * @since 2024-08-06 22:01
 */
public class Subscriber<T,V> {

    private Connection connection;
    private T topic;
    private V version;

    public Subscriber(Connection connection, T topic, V version) {
        this.connection = connection;
        this.topic = topic;
        this.version = version;
    }

    public Connection getConnection(){
        return connection;
    }
}
